Apache Kafka Cookbook by Saurabh Minni

Author:Saurabh Minni [Minni, Saurabh]
Language: eng
Format: epub, pdf
Publisher: Packt Publishing
Published: 2015-12-02T23:00:00+00:00

How to do it...

Use the following steps to write a simple consumer:

First find the partition information for the topic from the seed broker address that you have:SimpleConsumer consumer = new SimpleConsumer(seed, port, 100000, 64 * 1024, "leaderLookup"); List<String> topics = Collections.singletonList(topic); TopicMetadataRequest req = new TopicMetadataRequest(topics); TopicMetadataResponse resp = consumer.send(req); List<TopicMetadata> metaData = resp.topicsMetadata(); for (TopicMetadata item : metaData) { for (PartitionMetadata part : item.partitionsMetadata()) { if (part.partitionId() == partition) { returnMetaData = part; } } }

Download

Copyright Disclaimer:
This site does not store any files on its server. We only index and link to content provided by other sites. Please contact the content providers to delete copyright contents if any and email us, we'll remove relevant links or contents immediately.